package org.jeecg.modules.rabbitmq.producer;

//import com.rabbitmq.client.Channel;
//import com.rabbitmq.client.Connection;
//import com.rabbitmq.client.ConnectionFactory;

public class Producer {


//    private static final String QUEUE_NAME = "simple_queue";
//
//    public void producData(Object o) throws Exception {
//
//        ConnectionFactory factory = new ConnectionFactory();
//        factory.setHost("localhost");
//        try (Connection connection = factory.newConnection();
//             Channel channel = connection.createChannel()) {
//            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
//            String message = "Hello, RabbitMQ!";
//            channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
//        }
//    }
}
